#!/bin/bash
# 1. 使用Sqoop从MySQL导入数据到HDFS
sqoop import --connect jdbc:mysql://localhost:3306/YHXM \
--username root --password 123456 \
--table rdbms_cust_info \
--target-dir /sqoopdata/ods_cust_info_01 \
--split-by cust_id \
-m 1 \
--delete-target-dir;
echo "导入ods的数据到客户基表中"
# 2. 将HDFS数据加载到Hive表
hive -v -e "LOAD DATA INPATH '/sqoopdata/ods_cust_info_01/*' OVERWRITE INTO TABLE ods01.ods_cust_info_01;"
echo "导入完成，状态码: $?"

# 1. 使用Sqoop从MySQL导入数据到HDFS
sqoop import --connect jdbc:mysql://localhost:3306/YHXM \
--username root --password 123456 \
--table rdbms_org_info \
--target-dir /sqoopdata/ods_org_info_01 \
--split-by org_id \
-m 1 \
--delete-target-dir;
echo "导入ods的数据到客户基表中"
# 2. 将HDFS数据加载到Hive表
hive -v -e "LOAD DATA INPATH '/sqoopdata/ods_org_info_01/*' OVERWRITE INTO TABLE ods01.ods_org_info_01;"
echo "导入完成，状态码: $?"

# 1. 使用Sqoop从MySQL导入数据到HDFS
sqoop import --connect jdbc:mysql://localhost:3306/YHXM \
--username root --password 123456 \
--table rdbms_code_info \
--target-dir /sqoopdata/ods_code_info_01 \
--split-by code_id \
-m 1 \
--delete-target-dir;
echo "导入ods的数据到客户基表中"
# 2. 将HDFS数据加载到Hive表
hive -v -e "LOAD DATA INPATH '/sqoopdata/ods_code_info_01/*' OVERWRITE INTO TABLE ods01.ods_code_info_01;"